package com.shujia.userprofile.info.platform

import com.shujia.util.SparkRunner
import org.apache.spark.sql.{DataFrame, SparkSession}

object RegTimeUserTag extends SparkRunner {
  fieldName = "regTime"

  override def fetchTgg(spark: SparkSession, ds: String): DataFrame = {

    spark.sql(
      s"""
         |select
         | id,
         | create_time as regTime
         | from
         |dim.dim_pub_user_info_d_f
         |where ds='$ds'
         |
         |""".stripMargin)
  }
}
